# celery启动文件
from celery import Celery

# 为celery使用django配置文件进行设置
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")

# 创建celery实例
celery_app = Celery('celery_tasks')

# 加载celery配置，设置broker
celery_app.config_from_object('celery_tasks.config')

# 自动注册celery任务
# autodiscover_tasks参数是列表，列表中的元素是tasks的路径
celery_app.autodiscover_tasks(['celery_tasks.sms.tasks'])